#!/bin/bash
read -p "请输入你的ip地址："  ip_adr
read -p "请输入你的用户名："  Source_Username
read -p "请输入你的ip地址："  Source_Password

# 定义数据源数组
arr=(AML_CUSTOMER_MASTER AML_ACCOUNT_MASTER AML_TRANSACTION_DETAIL AML_UBO_INFO AML_WATCHLIST_MASTER AML_WATCHLIST_DETAIL AML_SCREENING_RESULT AML_ALERT AML_SUSPICIOUS_TXN_REPORT AML_MONITORING_RULE)
# 定义时间
dt=`date -d '1 days ago' '+%y%m%d'`

for tab in "${arr[@]}"
do
	sqoop import \
	--connect jdbc:oracle:thin:@"$ora_ip":1521/orcl \     #本机解析格式不同改,$ip_adr:orcl-->$ip_adr/orcl
    --username "$Source_Username" \		#源数据的用户名
    --password "$Source_Password" \		#源数据的密码
    --table "$tab" \						#源数据的表名
    --hcatalog-database ods \			#采用二进制形式存储格式_目标数据的库名
    --hcatalog-table "ods_$tab" \			#采用二进制形式存储格式_目标数据的表名
    --hive-partition-key etl_date \		#分区字段名
    --hive-partition-value "$dt" \		#分区字段值
	-m 1								#并行执行数量
done